草庐IT

CountDownLatch和ExecutorService 线程池cachedThreadPool.submit

全部标签

c++ - boost进程间容器适契约(Contract)进程线程共享存储吗?

我需要一个vector容器在同一进程的两个线程之间共享,为以下方法提供互斥保护访问:emptysizeerasepush_back我还希望集合提供一个迭代器,它在使用迭代器时锁定容器。本质上,我正在寻找一个std::vector的集合界面,但具有并发访问保护,但我似乎找不到任何东西。是boost::interprocess适合这种应用的容器?如果没有,是否有更合适的替代方案,还是我必须自己编写? 最佳答案 答案是肯定的——它是合适的。Seehere 关于c++-boost进程间容器适契约

多线程系列(六) -等待和通知模型详解

一、简介在之前的线程系列文章中,我们介绍了synchronized和volatile关键字,使用它能解决线程同步的问题,但是它们无法解决线程之间协调和通信的问题。举个简单的例子,比如线程A负责将int型变量i值累加操作到10000,然后通知线程B负责把结果打印出来。这个怎么实现呢?其中一个最简单的办法就是,线程B不断的通过轮询方式while(i==10000)检查是否满足条件,这样就可以实现了。虽然这种方式可以实现需求,但是也带来了另一个问题:线程B中的while()操作不会释放CPU资源,会导致CPU一直在这个方法上做判断操作,极大的浪费CPU资源。我们知道CPU资源是非常非常昂贵的,因为使

c++ - 关于线程的问题

我是线程编程的新手,我有一个概念上的问题。我正在做矩阵乘法作为我类(class)的一个项目。但是,我在不使用线程的情况下执行此操作,然后使用线程为答案矩阵的每个单元格计算标量积,然后再次将第一个矩阵分成多个比例,以便每个线程都有相等的部分要计算。我的问题是标量乘积实现完成得非常快,这是我所期望的,但是第三个实现并没有比非线程实现更快地计算出答案。例如,如果它使用2个线程,它会在大约一半的时间内完成计算,因为它可以同时处理矩阵的两半,但事实并非如此。我觉得第三个实现有问题,我不认为它是并行运行的,代码如下。谁能直接告诉我这个?并非所有代码都与问题相关,但我将其包括在内以防问题不是本地的。

c++ - 如何使用 vtk 实时可视化在另一个线程中运行的计算

我想使用可视化工具包在另一个线程中实时可视化正在运行的计算。计算吐出一组新的值,以便在每次迭代时可视化,图形线程必须知道这些并加载新值。一种方法是让主线程轮询计算的状态。理想情况下,我不想进行任何轮询,但如果没有其他方法,我会进行。我能想到的最好方法是让计算线程在每次计算迭代时将一个事件推送到主线程的事件队列中,然后由GUI进行处理。我不确定如何去做,或者是否可以以线程安全的方式完成。我在Linux上使用pthreads在gcc/C++中使用vtk。 最佳答案 在主线程中使用vtkCommand(或适当的派生类)监听您感兴趣的对象的

每天学一点之多线程

多线程一、相关概念并发与并行并行(parallel):指多个事件任务在同一时刻发生(同时发生)。并发(concurrency):指两个或多个事件在同一个微小的时间段内发生。程序并发执行可以在有限条件下,充分利用CPU资源。单核CPU:只能并发多核CPU:并行+并发线程与进程程序:为了完成某个任务和功能,选择一种编程语言编写的一组指令的集合。软件:1个或多个应用程序+相关的素材和资源文件等构成一个软件系统。进程是对一个程序运行过程(创建-运行-消亡)的描述,系统会为每个运行的程序建立一个进程,并为进程分配独立的系统资源,比如内存空间等资源。线程:线程是进程中的一个执行单元,负责完成执行当前程序的

c++ - 多线程 SQLite 崩溃

我正在尝试在多线程C++程序中使用SQLite3.7.5。我已将其缩小为几行简单的代码:sqlite3*Database;sqlite3_stmt*Stmt;intretval=sqlite3_open("database.db3",&Database);retVal=sqlite3_prepare(&Database,"CREATETABLERawData(KeyCHAR(5))",-1,&Stmt,0);retval=sqlite3_step(Stmt);retval=sqlite3_finalize(Stmt);当我直接从我的主进程调用这段代码时,它工作正常。但是,如果我使用Cr

Kafka-多线程消费及分区设置

目录一、Kafka是什么?消息系统:Publish/subscribe(发布/订阅者)模式相关术语二、初步使用1.yml文件配置2.生产者类3.消费者类4.发送消息三、减少分区数量1.停止业务服务进程2.停止kafka服务进程3.重新启动kafka服务4.重新启动业务服务参考文章一、Kafka是什么?Kafka是一种高吞吐量、分布式、基于发布/订阅的消息系统。可满足每秒百万级的消息生产和消费;有一套完善的消息存储机制,确保数据高效安全且持久化;Kafka作为一个集群运行在一个或多个服务器上,可以跨多个机房,当某台故障时,生产者和消费者转而使用其他的Kafka。消息系统:Publish/subs

c++ - Qt 在构建移动到线程的 QObject 时将 "this"作为父级传递

阅读文档后我发现了这个:ThechildofaQObjectmustalwaysbecreatedinthethreadwheretheparentwascreated.Thisimplies,amongotherthings,thatyoushouldneverpasstheQThreadobject(this)astheparentofanobjectcreatedinthethread(sincetheQThreadobjectitselfwascreatedinanotherthread).我不太确定这意味着什么,所以我举了几个例子,想知道这适用于什么地方。A.classMyT

c++ - 作用域和线程局部变量如何在(V8 的)C++ 中工作?

我对V8的作用域如何工作很感兴趣。堆栈上的作用域对象如何找到堆栈更上层的其他作用域对象和上下文?深入研究HandleScopes的工作原理后,我发现它们依赖于线程局部变量。这让我想知道这些在C++中是如何工作的,我已经找到了实现,但仍然觉得我不明白发生了什么。api.cc--HandleScope查找当前IsolateHandleScope::HandleScope(){i::Isolate*isolate=i::Isolate::Current();API_ENTRY_CHECK(isolate,"HandleScope::HandleScope");v8::Implementati

c++ - C++中原子变量的线程安全初始化

考虑以下C++11代码,其中类B被实例化并由多个线程使用。因为B修改了一个共享vector,所以我必须在B的构造函数和成员函数foo中锁定对它的访问。为了初始化成员变量id,我使用了一个计数器,它是一个原子变量,因为我从多个线程访问它。structA{A(size_tid,std::stringconst&sig):id{id},signature{sig}{}private:size_tid;std::stringsignature;};namespaceN{std::atomiccounter{0};typedefstd::vectorAs;std::vectorsharedRes